//
//  RxEMChatRoomDelegateObservable.swift
//  swiftim
//
//  Created by yangjian on 2023/8/7.
//

import Foundation

import HyphenateChat
import RxSwift



class RXEMChatroomObservable: NSObject,EMChatroomManagerDelegate {
    public let rx_userDidJoin = PublishSubject<(EMChatroom,String)>();
    public let rx_userDidLeave = PublishSubject<(EMChatroom,String)>();

    
    func userDidJoin(_ aChatroom: EMChatroom, user aUsername: String) {
        rx_userDidJoin.onNext((aChatroom,aUsername))
    }
    func userDidLeave(_ aChatroom: EMChatroom, user aUsername: String) {
        rx_userDidLeave.onNext((aChatroom,aUsername))
    }
    
        
}
